package com.sdy.mq.base;

import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

public abstract class BaseBatchMessageConsumer {
    protected abstract boolean consume(List<MessageExt> messageList);
}